-
Notifications
You must be signed in to change notification settings - Fork 21
CNDB-9697: notify JVMStabilityInspector when encountered corruption exception on compaction task #1901
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Checklist before you submit for review
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Makes sense to me
let's add unit tests
src/java/org/apache/cassandra/db/compaction/BackgroundCompactionRunner.java
Outdated
Show resolved
Hide resolved
4ba0ac5
to
616aa0d
Compare
@@ -460,6 +463,7 @@ public static void handleCompactionError(Throwable t, ColumnFamilyStore cfs) | |||
// we might have to rely on error message parsing... | |||
t = t instanceof FSError ? t : new FSWriteError(t); | |||
JVMStabilityInspector.inspectThrowable(t); | |||
CompactionManager.instance.incrementAborted(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'm not sure why isn't this incrementFailed();
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you are right. it should be failed
72deaca
to
f9bfcf9
Compare
…xception on compaction task
f9bfcf9
to
ca461bd
Compare
11e07ba
to
6c5e5f7
Compare
6c5e5f7
to
b2fe51a
Compare
|
✔️ Build ds-cassandra-pr-gate/PR-1901 approved by ButlerApproved by Butler |
What is the issue
Corruption excetion from compaction task didn't notify error handler.
Compaction aborted/failed metrics were not updated in some cases.
What does this PR fix and why was it fixed
Trigger JVMStabilityInspector for corruption exception from compaction task and update aborted/failed metircs properly.
Trigger JVMStabilityInspecto for error from repair validation.